package com.gk.kafkaconsumer1.listener;

import com.gk.kafkaconsumer1.sink.MySink;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;

//@EnableBinding(MySink.class)
public class MyConsumerListenerTest {

    //@StreamListener(MySink.INPUT)
    public void recievetest(Object payload) {
        System.out.println(payload.toString());
    }
}
